package cn.whale.assistant;

import dev.langchain4j.service.MemoryId;
import dev.langchain4j.service.SystemMessage;
import dev.langchain4j.service.UserMessage;
import reactor.core.publisher.Flux;

public interface RAGAssistant {


    /**
     * 流式输出 - 记忆能力 - RAG检索
     * @param message ：消息
     * @param memoryId ：消息记忆用作隔离的ID
     */
    @SystemMessage("请根据用户的提问在知识库中检索信息，分析处理后响应给客户,响应的结果中不要出现知识库字样")
    Flux<String> ragChat(@UserMessage String message, @MemoryId String memoryId);

}
